package biz.ws.ws;

/**
 * @创建人 wsdc
 * @时间 2021/4/2
 * @描述 消息发送者  确定消息如何发送
 * <li>    针对的是点对点的消息
 * <li>    如果发送的点在当前这个节点中 则直接返送 并且消息录入
 * <li>    如果发送的点不在当前这个节点中 则推送到kakfa对应的分区中 消息不做任何处理
 */
public interface MsgSender {
    void send(MsgHolder context);

    /**
     *  发送消息 同时回调
     */
    default void send(MsgHolder context, SendListener l){

    }


    interface SendListener {
        void beforePost();
        void success();
        void failure();
    }
}
